package cc.linker.steplink.crm.merchanth5.service;

import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;

@Slf4j
@Service
public class MqTimeService {

//    @Autowired
//    private AmqpTemplate amqpTemplate;
//
//
//    public void send(String msg, long time) {
//        LOGGER.info("促活队列发送时间: " + LocalDateTime.now() + " msg内容：" + msg);
//        MessagePostProcessor messagePostProcessor = new MessagePostProcessor() {
//            @Override
//            public Message postProcessMessage(Message message) throws AmqpException {
//                message.getMessageProperties().setHeader("x-delay", time);
//                return message;
//            }
//        };
//        amqpTemplate.convertAndSend("delayedExchange", "delayedQueue", msg, messagePostProcessor);
//    }

}
